const mysql = require('mysql');

const connection = mysql.createConnection({
    host: 'uhyper.ccol.cc',
    port: 3306,
    user: 'cyzk',   
    password: '1463a668e9a5eb41',
    database: 'cyzk'
});

// 查询所有账号
function getAllAccounts() {
    return new Promise((resolve, reject) => {
        connection.query('SELECT * FROM `账号`', (err, results) => {
            if (err) {
                reject(err);
                return;
            }
            resolve(results);
        });
    });
}

// 根据ID查询账号
function getAccountById(id) {
    return new Promise((resolve, reject) => {
        connection.query('SELECT * FROM `账号` WHERE id = ?', [id], (err, results) => {
            if (err) {
                reject(err);
                return;
            }
            resolve(results[0]);
        });
    });
}

// // 添加新账号
// function addAccount(account) {
//     return new Promise((resolve, reject) => {
//         connection.query('INSERT INTO `账号` SET ?', account, (err, results) => {
//             if (err) {
//                 reject(err);
//                 return;
//             }
//             resolve(results);
//         });
//     });
// }

connection.connect(err => {
    if (err) {
        console.log('数据库连接失败:', err.message);
    } else {
        console.log('数据库连接成功');
    }
});

let returnData = {
    flag: true,
    data: null
};

// 查询所有账号
getAllAccounts()
    .then(accounts => {
        console.log('所有账号:', accounts);
    })
    .catch(err => {
        console.error('查询失败:', err);
    });

// // 查询特定账号
// getAccountById(1)
//     .then(account => {
//         console.log('账号信息:', account);
//     })
//     .catch(err => {
//         console.error('查询失败:', err);
//     });

// // 添加新账号
// const newAccount = {
//     账号: 'test123',
//     密码: '123456',
//     日期: new Date()
// };

// addAccount(newAccount)
//     .then(result => {
//         console.log('添加成功:', result);
//     })
//     .catch(err => {
//         console.error('添加失败:', err);
//     });

module.exports = {
    connection,
    returnData,
    getAllAccounts,
    getAccountById,
    // addAccount,
    verifyLogin
};


// 验证登录的函数
function verifyLogin(account, password) {
    return new Promise((resolve, reject) => {
        connection.query(
            'SELECT * FROM `账号` WHERE 账号 = ? AND 密码 = ?',
            [account, password],
            (err, results) => {
                if (err) {
                    reject(err);
                    return;
                }
                resolve(results.length > 0);
            }
        );
    });
}